<?php

namespace app\queue\redisbak;

use app\common\lib\RedisQueue;
use app\common\lib\TencentCos;
use Webman\RedisQueue\Consumer;

class TestQueue implements Consumer
{
    // 要消费的队列名
    public $queue = 'test_queue';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($data)
    {
        var_dump($data);
        sleep(5);
        return ['data'=>$data,'result'=>time()];
    }
            
}
